import json

from app.api.generate.utils.generate_queue.mqtt import client


def start_listen_queue():
    client.loop_start()


def send_queue_message(topic, data):
    client.publish(topic, json.dumps(data))


